package com.codejiwei.sample

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

/**
 * Author: jiwei01
 * Date: 2022/12/26 16:48
 * Package: com.codejiwei.sample
 * Description:
 */
object Kafka2KafkaTest extends App {
  private val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
  env.setParallelism(2)



}
